package si;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.Statement;
import java.sql.Time;


import javafx.collections.FXCollections;
import javafx.collections.ObservableList;
import javafx.concurrent.Service;
import javafx.concurrent.Task;

public class ServicePobierzPilkarzy extends Service<ObservableList<Zawodnik>>{
	Connection conn = null;
	Statement st = null;
	private ObservableList<Zawodnik> lista = FXCollections.observableArrayList();
	String zapytanie = "";
	
	
	public void setZapytanie(String zap){
		zapytanie = zap;
	}
	
	@Override
	protected Task<ObservableList<Zawodnik>> createTask() {
		return new Task<ObservableList<Zawodnik>>(){

			@Override
			protected ObservableList<Zawodnik> call() {
				
				lista = FXCollections.observableArrayList();
				try{
					conn = Baza.polacz("pilkarze");
					st = conn.createStatement();
					
					ResultSet rs = st.executeQuery(zapytanie);
					while(rs.next()) {
						
						String imie = rs.getString(1);
						String nazwisko = rs.getString(2);
						String pozycja = rs.getString(3);
						int wiek = rs.getInt(4);
						int wzrost = rs.getInt(5);
						int waga = rs.getInt(6);
						float wartosc = rs.getFloat(7);
						Zawodnik p = new Zawodnik(imie, nazwisko, pozycja, wiek, wzrost, waga, wartosc);
						lista.add(p);
					}
				}catch(Exception e){
					e.printStackTrace();
					System.out.println("B��d "+e);
					return null;
				}
				return lista;
			}
		};//koniec return
	}

}
